
#include "../Client/RpcClient.hpp"
/*
创建客户端和服务中心链接，然后创建主题推送消息
*/
void DealComment(const std::string &topicname, const std::string &msg)
{
    DLOG("收到主题:%s的推送内容:\n%s",topicname.c_str(),msg.c_str());
}
int main()
{
    // 1 向服务中心发起网络连接
    auto client = std::make_shared<RpcClient::TopicClient>("127.0.0.1", 9090);

    // 2 向服务中心发送创建主题请求
    client->create("Hellow");

    // 3 订阅该主题的内容给订阅客户端，主线程设置回调函数，监听线程等待服务中心回应然后调用回调函数处理
    client->subscribe("Hellow",DealComment);

    //4 等待主题内容的推送
    while(true);
}